package coop.tecso.capacitaciones.threads.mensaje;

public class Receptor extends Thread {

	private Canal canal;
	private String mensajeRecibido = null;

	public Receptor(Canal canal) {
		super();
		this.canal = canal;
	}

	@Override
	public void run() {
		try {
			// recibe un mensaje del canal al que esta escuchando
			mensajeRecibido = canal.get();
		} catch (Exception e) {
			System.out.println("Consumidor **** Exception al consumir");
			// error al obtener el mensaje
			// mensajeRecibido queda en null
		}
	}

	public String getMensajeRecibido() {
		return mensajeRecibido;
	}


}
